package com.wo.cloud.kafka.channel;


import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * 日志消息通道
 */
public interface LogChannel {

    /**
     * 输入通道名称
     */
    String LOG_INPUT= "log_input";

    /**
     * 输出通道名称
     */
    String LOG_OUTPUT="log_output";


    /**
     * 定义发送消息通道
     * @return
     */
    @Output(LOG_OUTPUT)
    MessageChannel sendLogMessage();


    /**
     * 定义订阅消息通道
     */
    @Input(LOG_INPUT)
    SubscribableChannel receiveLogMessage();
}
